
#include <sys/types.h>
#include <sys/stat.h>

#include "comm.hpp"
using namespace std;

int main()
{
    // 1.server创建命名管道
    umask(0); // 这个设置不影响系统的默认值，只影响当前进程
    int mf = mkfifo(pathname.c_str(), mode);
    if (mf == -1) // 创建失败
    {
        cout << "mkfifo error:" << errno << ":" << strerror(errno) << endl;
        return 1;
    }
    cout << "打开管道文件" << endl;
    // 2.server去打开这个管道文件--》server从这个管道文件读取数据
    int rfd = open(pathname.c_str(), O_RDONLY);
    if (rfd == -1) // 文件打开失败
    {
        cout << "open error" << errno << ":" << strerror(errno) << endl;
        return 2;
    }
    cout << "开始通信" << endl;
    // 3.正常通信
    while (true)
    {
        char buffer[NUM];
        int n = read(rfd, buffer, sizeof(buffer) - 1); // read字节流读取，留最后一位字节空间填'\0'
        if (n > 0)
        {
            buffer[n] = 0;
            // cout<<"#client send massage:"<<buffer<<endl;
            //cout << "#client:" << buffer << endl;
            cout<<buffer;
            fflush(stdout);
        }
        else if (n == 0)
        {
            cout << "client quit,me too!" << endl;
            break;
        }
        else // 读取数据失败
        {
            cout << "read error" << errno << ":" << strerror(errno) << endl;
            return 3;
        }
    }
    // 4.读取结束，关闭文件
    close(rfd);
    // 5.删除文件
    unlink(pathname.c_str());
    return 0;
}